package com.yifeng.repo.flink.data.transport.config;

import java.io.Serializable;

import lombok.Data;

@Data
public class SourceDbConfig implements Serializable {

	private static final long serialVersionUID = 1L;
	
	/**
	 * 源库的地址
	 */
	private String hostname;

	/**
	 * 源库的端口
	 */
	private Integer port;

	/**
	 * 源库的库名
	 */
	private String database;
	
	/**
	 * 源库的用户名列表,用逗号隔开
	 */
	private String schemaList;
	
	/**
	 * 源库的表名列表,用逗号隔开
	 */
	private String tableList;
	
	/**
	 * 源库的连接用户
	 */
	private String username;
	
	/**
	 * 源库的连接密码
	 */
	private String password;
	
	/**
	 * 源库流式读取的一次性读取的数量
	 */
	private String fetchSize;
	
	/**
	 * 源库的多表并行读取的并行度
	 */
	private Integer parallelism;
	
	private String columnIncludeList;
	
	private String columnExcludeList;
	
	/**
	 * 需要执行同步的sql语句
	 */
	private String sqlMap;
	
}
